package com.wanjl.mq.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author WanJl
 * @version 1.0
 * @title QueueConfig
 * @description RabbitMQ队列(queue)配置类
 * @create 2025/2/10
 */
@Configuration
public class QueueConfig {
    /**
     * 创建一个广播队列fanout.queue1
     * @return
     */
    @Bean
    public Queue fanoutQueue01() {
        return new Queue("fanout.queue1");
    }

    /**
     * 创建一个广播队列fanout.queue2
     * @return
     */
    @Bean
    public Queue fanoutQueue02() {
        return new Queue("fanout.queue2");
    }


}
